package com.changdu.seatunnel.admin.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;

import lombok.Data;

@Data
@TableName("sync_config")
public class SyncConfig {
	
    @TableId(type = IdType.AUTO)
    private Long id;
    
    // 源数据库配置
    private String sourceDataCenter;
    private String sourceInstance;
    private String sourceDatabases;
    private String sourceTables;
    private Integer sourceTemplate;
    
    // 目标数据库配置
    private String targetDataCenter;
    private String targetInstance;
    private String targetDatabases;
    private String targetTables;
    private Integer targetTemplate;
    
    // 表映射配置
    private String tableMappings;
    
    // 配置状态：0-草稿，1-已生成，2-已发布
    private Integer status;
    
    // 创建时间
    private String createTime;
    
    // 更新时间
    private String updateTime;
    
    private String kafkaTopic;
    private Integer kafkaPartition;
    private String kafkaConsumerGroup;
} 